package org.yonggan.shop.utils

import org.apache.spark.sql.{DataFrame, SparkSession}

/**
  * 执行sql数据
  */
object SQLUtils {


  /**
    * SQL执行
    *
    * @param sql
    * @param spark
    */
  def executor(sql: String, spark: SparkSession):DataFrame = {
    spark.sql(sql)
  }

}
